package com.hsgene.util.mq.rocket.consumer;


import com.aliyun.openservices.ons.api.Action;
import com.aliyun.openservices.ons.api.Message;

/**
 * MQ消息监听抽象处理接口-主要处理业务逻辑
 *
 * @author wangbing
 * @version 1.0
 * @date 2019/1/16 14:25
 * Copyright: Copyright (c) 2019
 */
public interface IRocketMQListener {

    /**
     * 消息消费抽象处理方法
     *
     * @param message 具体消息
     * @return 消息消费结果
     */
    default Action messageHandler(Message message) {
        throw new UnsupportedOperationException("不支持的RocketMQ消息处理操作");
    }
}
